package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.pojo.PointProtocol;
import com.navinfo.tripanalysis.offline.pojo.DataCleaningInfo;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.sql.SparkSession;

import java.util.List;

/**
 * 数据清洗：保存公共位置协议的服务
 * @author hmc
 */
public interface SavePointDataCleaningService {
     void save(SparkSession spark, JavaPairRDD<Long, List<PointProtocol>> pairTidOutData, long d);
}
